package com.gas.activemq.Embed;

import org.apache.activemq.broker.BrokerService;

/**
 * @author guoshoudu
 * @version 1.0
 * @description
 * @date 2021/6/29 4:01 下午
 */
public class EmbedBroker {
    public static void main(String[] args) throws Exception {
        //ActiveMQ也支持在vm中通信基于嵌入的broker，能够无缝的集成其他java应用。
        BrokerService brokerService=new BrokerService();
        brokerService.setUseJmx(true);
        brokerService.addConnector("tcp://127.0.0.1:61616");
        brokerService.start();
    }
}
